package dataflowscheme.engine.core;

import java.util.concurrent.LinkedBlockingQueue;

import org.apache.log4j.Logger;

/**
 * Encapsulate data-flow Storage entity.
 * 
 * @author <a href="mailto:misiak7@gmail.com">Michal Antolik</a>
 *
 */
public class CStorage extends PE {

	static protected Logger log = Logger.getLogger(CStorage.class);
	
	public CStorage(dataflowScheme.Storage estorage, LinkedBlockingQueue<IEvent> queue, LinkedBlockingQueue<IExecutionEvent> executionQueue){
		super(estorage, queue, executionQueue);
	}

	/**
	 * start new execution
	 */
	protected void schedule(int portset) {
		IExecutionEvent event = new StorageExecutionEvent(this, portset);
		executionQueue.offer(event);
	}

}
